package ru.gerunn.silent.message;

public class MessageThread implements Runnable {

	private MessageQueue queue;

	public MessageThread(MessageQueue queue) {
		this.queue = queue;
	}

	public void run() {
		@SuppressWarnings("unused")
		Message message;
		try {
			while ((message = queue.get()) != null) {
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}

}
